1 package org.smartcomps.twister.engine.core.definition;
2
3 import junit.framework.TestCase;
4 import net.sf.hibernate.tool.hbm2ddl.SchemaExport;
5 import net.sf.hibernate.cfg.Configuration;
6 import org.smartcomps.twister.common.transaction.TransactionManager;
7 import org.smartcomps.twister.common.persistence.XMLDataAccess;
8 import org.smartcomps.twister.common.lifecycle.LifecycleManager;
9 import org.smartcomps.twister.util.BeanTester;
10 import org.smartcomps.twister.engine.priv.core.definition.ActivityFactory;
11 import org.smartcomps.twister.engine.priv.core.definition.Assign;
12 import org.smartcomps.twister.engine.priv.core.definition.ProcessFactory;
13 import org.smartcomps.twister.engine.priv.core.definition.Assignment;
14 import org.smartcomps.twister.engine.priv.core.definition.Sequence;
15 import org.smartcomps.twister.engine.priv.core.definition.Receive;
16 import org.smartcomps.twister.engine.priv.core.definition.CorrelationRef;
17
18 public class TestAssign extends TestCase {
19
20 public static Assign assign = null;
21
22 private BeanTester beanTester = new BeanTester(new String[] {"Id", "Index"});
23 private TestProcess testProcess = new TestProcess();
24
25 protected void setUp() throws Exception {
26 LifecycleManager.getLifecycleManager().createResources();
27 LifecycleManager.getLifecycleManager().startResources();
28
29 SchemaExport schemaExport = new SchemaExport(new Configuration().configure());
30 schemaExport.create(true, true);
31
32 TransactionManager.beginTransaction();
33 testProcess.testCreate();
34 }
35
36 protected void tearDown() throws Exception {
37 TransactionManager.commitTransaction();
38
39 LifecycleManager.getLifecycleManager().stopResources();
40 LifecycleManager.getLifecycleManager().destroyResources();
41 }
42
43 public void testCreate() throws Exception {
44 Sequence sequence = (Sequence) ActivityFactory.createActivity(Sequence.class, TestProcess.testProcess);
45 Receive receive = (Receive) ActivityFactory.createActivity(Receive.class, sequence);
46 ActivityFactory.addCorrelationRef(receive, TestProcess.CORRELATION_NAME, false, CorrelationRef.NONE);
47 assign = (Assign) ActivityFactory.createActivity(Assign.class, sequence);
48 Assignment assignment = ActivityFactory.addAssignment(assign, Assignment.VARIABLE_PART, Assignment.VARIABLE_PART);
49 assignment.setFromFirstValue("variable1");
50 assignment.setFromSecondValue("part11");
51 assignment.setToFirstValue("variable2");
52 assignment.setToSecondValue("part21");
53
54 beanTester.initializeProperties("testAssign", assign);
55
56 TransactionManager.commitTransaction();
57 TransactionManager.beginTransaction();
58
59 Assign resultAssign = (Assign)((Sequence) ProcessFactory.getByName(TestProcess.testProcess.getName()).getActivity()).getActivities().get(1);
60 assertTrue("Assign attributes values have been changed.", beanTester.testValues("testAssign", resultAssign));
61 assign = resultAssign;
62 }
63
64 }
This page was automatically generated by Maven